const router = require('koa-router')()
const connection = require('./db'); // 导入数据库连接对象
const query = 'SELECT * FROM master';
router.get("/getmaster", async (ctx, next) => {
    try {
      // 使用 Promise 封装数据库查询
      const queryAsync = () => {
        return new Promise((resolve, reject) => {
          connection.query(query, function (error, results, fields) {
            if (error) {
              reject(error);
            } else {
              resolve(results);
            }
          });
        });
      };
  
      // 使用 await 等待查询结果
      const list = await queryAsync();
      //console.log(JSON.stringify(list));
      const parsedList = JSON.parse(JSON.stringify(list)); 
      console.log(parsedList);
      ctx.body = {
            list: parsedList,
        };
    } catch (error) {
      // 处理错误
      console.error(error);
      ctx.status = 500;
      ctx.body = "Internal Server Error";
    }
  });

  router.post('/getmasteradd', async (ctx) => {
    let requestData = ctx.request.body; // 从请求中获取数据
    let isOn1 = ctx.request.body.isOn1;
    console.log(isOn1); // 输出接收到的数据
    try {
        const updateQuery = 'UPDATE master SET `add` = ? WHERE id = 1';  // 假设id为1的行是你希望更新的目标行
        const updateParams = [isOn1]; // 更新的值
        await connection.query(updateQuery, updateParams);
        ctx.body = "Update successful";
      } catch (error) {
        console.error('Error updating data:', error);
        ctx.status = 500; // 服务器内部错误
        ctx.body = "Internal Server Error";
      }
  })


  router.post('/getmasterdel', async (ctx) => {
    let requestData = ctx.request.body; // 从请求中获取数据
    let isOn2 = ctx.request.body.isOn2;
    console.log(isOn2); // 输出接收到的数据
    try {
        const updateQuery = 'UPDATE master SET `del` = ? WHERE id = 1';  // 假设id为1的行是你希望更新的目标行
        const updateParams = [isOn2]; // 更新的值
        await connection.query(updateQuery, updateParams);
        ctx.body = "Update successful";
      } catch (error) {
        console.error('Error updating data:', error);
        ctx.status = 500; // 服务器内部错误
        ctx.body = "Internal Server Error";
      }
  })
  module.exports = router;